package cn.xyinping._04_direct;

import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * @author 27266
 * @desrciption 消费者
 * @date 2021/11/12
 */
public class Consumer2 {
    // 队列名
    private final static String QUEUE_NAME_DIRECT2 = "queue_name_direct2111";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 1. 创建RabbitMQ链接
        ConnectionFactory factory  = new ConnectionFactory();
        Connection connection = factory.newConnection();
        // 2. 创建通道
        Channel channel = connection.createChannel();
        // 声明队列
        channel.queueDeclare(QUEUE_NAME_DIRECT2,
                false, // 持久化
                false, // 独占链接
                false, // 自动删除
                null); // 其他属性
        // 绑定队列到交换机
        channel.queueBind(QUEUE_NAME_DIRECT2, // 队列
                Producer.PRODUCER_EXCHANGE_NAME_DIRECT, // 交换机
                "info");
        // 拉去消息的数量，同时只能处理一个消息
//        channel.basicQos(1);
        // 消息处理回调
        // 全限定名防止冲突
        Consumer callback = new DefaultConsumer(channel){
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, // 信封
                                       AMQP.BasicProperties properties, byte[] body) throws IOException {
                super.handleDelivery(consumerTag, envelope, properties, body);
                System.out.println("消息:"+new String(body));
                System.out.println("consumerTag："+consumerTag);
                System.out.println("交换机："+envelope.getExchange());
                System.out.println("队列：" +envelope.getRoutingKey());
                System.out.println("消息的Id："+envelope.getDeliveryTag());
                // 手动签收
                channel.basicAck(envelope.getDeliveryTag(), // 消息Id
                        false); // 是否签收多个消息
            }
        };
        // 3.监听队列
       channel.basicConsume(QUEUE_NAME_DIRECT2, // 队列名
               false, // 是否自动签收  如果消息消费失败可能会导致消息丢失，改成手动签收
                callback); // 消息处理回调
    }

}
